//package com.ruoyi.cluster;
//
//import org.apache.curator.RetryPolicy;
//import org.apache.curator.framework.CuratorFramework;
//import org.apache.curator.framework.CuratorFrameworkFactory;
//import org.apache.curator.retry.ExponentialBackoffRetry;
//import org.springframework.beans.factory.annotation.Value;
//import org.springframework.context.annotation.Bean;
//import org.springframework.context.annotation.Configuration;
//
//@Configuration
//public class ZookeeperConfig {
//	
//    @Value("${zookeeper.enable}")
//    private boolean enable;
//    
//    @Value("${zookeeper.podKey}")
//    private String podKey;
//
//    @Value("${zookeeper.connect-string}")
//    private String connectString;
//
//    @Value("${zookeeper.session-timeout}")
//    private int sessionTimeout;
//
//    @Value("${zookeeper.connection-timeout}")
//    private int connectionTimeout;
//
//    @Value("${zookeeper.base-sleep-time}")
//    private int baseSleepTime;
//
//    @Value("${zookeeper.max-retries}")
//    private int maxRetries;
//
//    @Bean
//    public CuratorFramework curatorFramework() {
//    	if(!enable) {
//    		return null;
//    	}
//        RetryPolicy retryPolicy = new ExponentialBackoffRetry(baseSleepTime, maxRetries);
//        CuratorFramework client = CuratorFrameworkFactory.builder()
//                .connectString(connectString)
//                .sessionTimeoutMs(sessionTimeout)
//                .connectionTimeoutMs(connectionTimeout)
//                .retryPolicy(retryPolicy)
//                .build();
//        client.start();
//        return client;
//    }
//
//	public boolean isEnable() {
//		return enable;
//	}
//
//	public String getPodKey() {
//		return podKey;
//	}
//    
//}
